package net.wicp.tams.common.others.kafka;

import java.util.List;

import org.apache.kafka.clients.consumer.ConsumerRecord;

import net.wicp.tams.common.Result;

public interface IConsumer<T> {

	/***
	 * 批处理
	 * 
	 * @param consumerRecords
	 * @return
	 */
	public Result doWithRecords(List<ConsumerRecord<String, T>> consumerRecords);
}
